
HADOOP_CMD="/opt/hadoop/bin/hadoop"
STREAM_JAR_PATH="/opt/hadoop/share/hadoop/tools/lib/hadoop-streaming-3.0.3jar"

INPUT_FILE_PATH="/The_Man_of_Property.txt"
OUTPUT_PATH="/output"

$HADOOP_CMD fs -rmr -skipTrash $STREA_JAR_PATH \
    -input $INPUT_FILE_PATH \
    -mapper "python map.py" \
    -reducer "python red.py" \
    -file ./map.py \
    -file ./red.py
